﻿using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using MySql.Data.MySqlClient;
using PUCP.SI2.SGIRP.BE;
using System.Data;

namespace PUCP.SI2.SGIRP.DA
{
    public class DAOCC
    {
        public void addCC(CentroComercialBE cc)
        {
            MySqlConnection conn = new coneccion().getInstance();
            conn.Open();

            try
            {
                MySqlCommand command = new MySqlCommand("INSERT into centro_comercial (nombre, abreviatura, areaArrendable, areaTotal," +
                "direccion, departamento, provincia, distrito, telefono, numNiveles, fecApertura, observaciones, estado, codAdmin, codProp, codCateg)" +
                " VALUES (@nom, @abrev, @arArr, @arTot, @dir, @dep, @prov, @dist, @telf, @nNiv, @fecha, @obs, @est, @codA, @codP, @codC)", conn);


                command.Parameters.Add("@nom", cc.Nombre);
                command.Parameters.Add("@abrev", cc.Abreviatura);
                command.Parameters.Add("@arArr", cc.AreaArrendable);
                command.Parameters.Add("@arTot", cc.AreaTotal);
                command.Parameters.Add("@dir", cc.Direccion);
                command.Parameters.Add("@dep", cc.Departamento);
                command.Parameters.Add("@prov", cc.Provincia);
                command.Parameters.Add("@dist", cc.Distrito);
                command.Parameters.Add("@telf", cc.Telefono);
                command.Parameters.Add("@nNiv", cc.NumeroNiveles);
                command.Parameters.Add("@fecha", cc.FechaApertura);
                command.Parameters.Add("@obs", cc.Observaciones);
                command.Parameters.Add("@codA", 1);
                command.Parameters.Add("@codP", 1);
                command.Parameters.Add("@codC", 1);

                command.ExecuteNonQuery();
                conn.Clone();
            }
            catch (Exception ex)
            {
                Console.Out.WriteLine(ex.StackTrace);
            }
        }

        public List<CentroComercialBE> QueryCC()
        {
            MySqlConnection conn = new coneccion().getInstance();
            List<CentroComercialBE> list = new List<CentroComercialBE>();
            conn.Open();

            String query = "SELECT * FROM centro_comercial WHERE estado = 1";
            MySqlCommand cmd = new MySqlCommand(query, conn);

            MySqlDataReader rd = cmd.ExecuteReader();

            while (rd.Read())
            {
                int codigo = rd.GetInt32("codigo");
                String nombre = rd.GetString("nombre");
                String abreviatura = rd.GetString("abreviatura");
                String direccion = rd.GetString("direccion");

                CentroComercialBE cc = new CentroComercialBE();
                cc.Codigo = codigo;
                cc.Nombre = nombre;
                cc.Abreviatura = abreviatura;
                cc.Direccion = direccion;

                list.Add(cc);
            }
            return list;
        }

        public DataTable getCmbCentroComercial()
        {
            DataTable dtCentroC=null;
            MySqlConnection conn = new coneccion2().getInstance();
            MySqlDataAdapter daCentroco = null;
            conn.Open();
            String sqlString = "select codigo,nombre from centro_comercial order by 2";

            //MySqlCommand cmd = new MySqlCommand(sqlString, conn);
           // MySqlDataReader rd = cmd.ExecuteReader();
            daCentroco = new MySqlDataAdapter(sqlString, conn);
            dtCentroC = new DataTable("centro_comercial");
            daCentroco.Fill(dtCentroC);
            return dtCentroC;
        }
    }
}
